"""
---------------------------------------------------------------------
- File: producer_main.py
- Date: 2025/5/29
- Author: yangzhide
- Email: xxzjyzd@126.com
- Description: 简单的生产者代码，连接rabbitmq，声明一个队列，发送消息到队列中。
---------------------------------------------------------------------
"""

import pika

# 使用pika库连接rabbitmq
connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost"))
# 创建一个channel通道
channel = connection.channel()

# 声明一个队列，确保队列存在
channel.queue_declare(queue="hello")

# 1. 简单模式：发送一条消息到队列中
channel.basic_publish(exchange="",routing_key='hello',body="666666")

# 关闭连接
connection.close()